package com.teaphy.coroutinecrawler.flow.operators.filter

import kotlinx.coroutines.flow.*
import kotlinx.coroutines.*

fun main() = runBlocking {
    flow {
        repeat(10) {
            emit(it)
            delay(110)
        }
    }.sample(200)
        .collect {
            println("receive: $it")
        }
}